4168beb8137d2220d9246cac331a244fe6e730c8,streams-contrib/streams-provider-google/google-gplus/src/main/java/com/google/gplus/provider/GPlusUserActivityProvider.java,GPlusUserActivityProvider,main,#String[]#,82
Before Change
provider.startStream();
do {
Uninterruptibles.sleepUninterruptibly(streamsConfiguration.getBatchFrequencyMs(), TimeUnit.MILLISECONDS);
Iterator<StreamsDatum> iterator = provider.readCurrent().iterator();
while(iterator.hasNext()) {
StreamsDatum datum = iterator.next();
String json;
if (datum.getDocument() instanceof String)
json = (String) datum.getDocument();
After Change
provider.startStream();
do {
Uninterruptibles.sleepUninterruptibly(streamsConfiguration.getBatchFrequencyMs(), TimeUnit.MILLISECONDS);
for (StreamsDatum datum : provider.readCurrent()) {
String json;
if (datum.getDocument() instanceof String)
json = (String) datum.getDocument();